﻿

<?php

session_start();
header("Content-Type: text/html; charset=utf-8");
include_once( 'config.php' );
include_once( 'weibooauth.php' );


//**************用某个用户的固定token取数据**********************
$a = "707f5c6e978c5cb39e1d883ba9e2705c";
$b = "ec7011db857771d5fdf72530303c9bcb";
$c = new WeiboClient( WB_AKEY , WB_SKEY , $a , $b  );
//**************用某个用户的固定token取数据**********************
//$c = new WeiboClient( WB_AKEY , WB_SKEY , $_SESSION['last_key']['oauth_token'] , $_SESSION['last_key']['oauth_token_secret']  );
$ms  = $c->home_timeline(); // done,   mike：选择类的某个出来方法，本行选择是timeline函授
$me = $c->verify_credentials();

//print_r($ms);  测试使用
echo $me['name'] ."你好~ 要换头像么?";

//××××××××××××××××校验用户列表是否有该用户，若没有就添加一条记录。××××××××××××××××××××××××××××××××
	$name=$me['name']; //由于不能直接用右边的内容，所以用了个变量作为中介。
	$id=$me['id']; 

$con = mysql_connect("localhost", "root","");   



mysql_query("SET NAMES utf8");   //下面3行是解决sql写入写出显示乱码的，详细见http://wenwen.soso.com/z/q104200853.htm
mysql_query("SET CHARACTER SET utf8");
mysql_query("SET COLLATION_CONNECTION='utf8_general_ci'");
if (!$con)
  {
  die('Could not connect: ' . mysql_error());
  }
  
  mysql_select_db("movie3", $con);      //先选择数据库
  
  
/*  
 $sql = "SELECT * FROM user WHERE weibo_id='$id'";
 $result = mysql_query($sql,$con);         //执行上面一行的sql
 
 if (mysql_num_rows($result))              //判断是否该用户id存在，即是否有结果记录
  {
  echo "帐号已注册";
  }
  else
   {
  $sql = "INSERT INTO user (weibo_id, name)     
VALUES ( '$id', '$name' )" ;               //若不存在插入用户id
  }
mysql_query($sql,$con); //执行上面语句
*/
//××××××××××××××××校验用户列表是否有该用户，若没有就添加一条记录。××××××××××××××××××××××××××××××××





//start ××××××××××从数据的电影表，获取电影关键字,放入到临时数组×××××××××××××××××××××××

 $sql = "SELECT * FROM movie WHERE endtime  > unix_timestamp() and new_set=0 " ;  // 根据“下影时间” 和 new标记位（下影时间晚于当天）过滤出所有电影数据 
 $result = mysql_query($sql,$con);         //执行上面一行的sql
 
 if ( !mysql_num_rows($result) )                   //判断是否有未刷新数据，若为空，就把它全部置0
     {
	  $sql = "UPDATE  movie  SET new_set=0  where endtime > CURDATE()"; 
	  $result = mysql_query($sql,$con);
	  exit;
	 }
 
	 $i=0;
	while( $row=mysql_fetch_array($result) )   //循环取查询结果的每行数据
	{
	  $rows_keyword[$i]=$row;
	  echo "<br/>测试显示电影名" .$rows_keyword[$i][title] ;    //结果为多维数组
	  $i++;
	  $j=$i;  	 //把关键字的个数传递给 变量j，以便后续循环使用
	}
//end×××××××××××从数据的电影表，获取电影关键字,放入到临时数组××××××××××××××××××







/* START××××××××××××××××××××××××× 循环 从搜索接口取"最新"的数据，并写如数据库 ×××××××××××××××××××××× */
		
	//mysql_query("TRUNCATE   TABLE comment_new",$con);  //删除表的内容,测试阶段使用	
	for( $i=0; $i<=$j; $i++)   // 从搜索关键字数组里关键字的个数，启动相应次数的循环。
	{	
	    
		$movie_id = $rows_keyword[$i][id];
		$sql = "UPDATE  movie  SET new_set=1  where id=$movie_id"; //刷新 标记位，“1”表示已刷新
		$result = mysql_query($sql,$con);
		
	   
		$keyword = $rows_keyword[$i][keyword];
	 	$search = $c->search( $keyword, 20, 5 );  //选择原创的内容
		//print_r($search);
		if( !is_array( $search ) )  { echo "-----你可能还没有登录，所有看不到数据-----"; exit; }   //做个判断，看是否调用到接口数据
			foreach( $search as $item )  //从timeline逐条读出微博
					{ 
				    $sql = "SELECT * FROM comment_new WHERE  weibo_id='$item[id]' " ;    //若有关键字，就用该微博id与数据库比较一下，看是否已经有该微博。
					$result = mysql_query($sql,$con);   
							if ( mysql_num_rows($result) )      //有相同id存在就不写入数据库
							{ }
							else 
							{   //若没有该微博，就执行写操作，把该条微博写入数据库。		
														
							//因为二位数组在sql赋值有问题，所以通过变量进行中转。
							$create_time = date("Y-m-d H:i:s", strtotime($item[created_at], time())); // 把从微博获取的时间格式转为timestamp，再转为合适的时间格式
							$movie_id = $rows_keyword[$i][movie_id]; 				 // 电影id
							$retweeted_id = $item[retweeted_status][id];       		 //转发id
							$user_id = $item[user][id];								//用户id
							$user_name = $item[user][name];							//用户名
							$user_url = "http://t.sina.com.cn/".$item[user][id];		//用户url
							$user_profile_image = $item[user][profile_image_url];	//用户头像
							//echo "测试这个数据". $item[thumbnail_pic] . "</br>";
											 
							 $sql = "INSERT INTO comment_new ( movie_id, created_at, text, weibo_id, reflash_time, retweeted_status, retweeted_id, source, user_id, user_name, user_url, profile_image_url, thumbnail_pic, bmiddle_pic, original_pic  ) 
							 VALUES ( '$movie_id', '$create_time', '$item[text]',  '$item[id]', now(), '$item[retweeted_status]', '$retweeted_id', '$item[source]', '$user_id', '$user_name', '$user_url', '$user_profile_image', '$item[thumbnail_pic]', '$item[bmiddle_pic]', '$item[original_pic]' )" ;  //  这条语句是 最新数据
					  //待补充，这里需补充一个判断，若有retweeted_id的值存在，则把retweeted值置为1，否则为0 
							mysql_query($sql,$con);
							//mysql_query($sql,$con3);
						
							}					
					} 				 	
		$sql = "select * from comment_new";
		$result = mysql_query($sql,$con);
		//while($row = mysql_fetch_assoc($result))    
		//echo " 。。。测试：....".$row['text']."</br>";  
		//  var_dump($row); //测试用，打印数据 
				//print_r($search);
			
		
		break;         //页面每次只执行一个电影刷新
	}	
	
	//exit;
/* END××××××××××××××××××××××××× 从搜索接口 取最新的数据，并写入数据库 ×××××××××××××××××××××× */




mysql_close($con); ?> 
